package com.glela.statistics.amqp;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.glela.statistics.service.UserEarningsService;

/**
 * **********************************************
 * 
 * @Title 计算收益监听队列
 * @throws @author gaoweiqi
 * @date 2018年03月06日 上午11:20:00 
 * **********************************************
 */
public class CalculationEarnings {
	private static Logger logger = LoggerFactory.getLogger(CalculationEarnings.class);
	private UserEarningsService userEarningsService;

	public void onMessage(String orderSn) {
		try {
			//userEarningsService.CalculateEarningsWithCache(orderSn);
		} catch (Exception e) {
			logger.error("重新计算收益失败 相关订单号:{} error:{}",orderSn,e.getMessage());
		}
	}

	public UserEarningsService getUserEarningsService() {
		return userEarningsService;
	}

	public void setUserEarningsService(UserEarningsService userEarningsService) {
		this.userEarningsService = userEarningsService;
	}
}
